package servlet;

import util.StringUtil;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Arrays;

/**
 * @author 石小俊
 */
// 注解中有且仅有urlPatterns属性时,可以直接写属性值
@WebServlet("/addEmp")
public class AddEmpServlet extends HttpServlet {
    @Override
    protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 设置响应字符集
        // response.setCharacterEncoding("utf-8");
        // 设置响应数据格式,其参数格式为:数据格式;charset=字符集
        // text/html表示html文本
        response.setContentType("text/html;charset=utf-8");
        PrintWriter out = response.getWriter();
        System.out.println("************************正在添加员工信息************************");
        // 在Servlet中获取的请求的中数据时,返回值始终是字符串或者字符串数组类型
        String name = request.getParameter("name");
        String salary = request.getParameter("salary");
        String gender = request.getParameter("gender");
        String edu = request.getParameter("edu");
        String[] hobbies = request.getParameterValues("hobbies");
        System.out.println("name:" + name + ",salary:" + salary + ",gender:" + gender + ",edu:" + edu + ",hobbies:" + Arrays.toString(hobbies));

        Connection conn = null;
        PreparedStatement ps = null;
        String url = "jdbc:mysql://127.0.0.1:3306/web?useUnicode=true&characterEncoding=utf-8";
        try {
            // 1.注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2.获取连接
            conn = DriverManager.getConnection(url, "root", "root");
            // 3.获取状态机
            String sql = new StringBuffer()
                    .append(" insert into ")
                    .append(" t_emp ")
                    .append("   (name,salary,gender,edu,hobbies)")
                    .append(" values ")
                    .append("   (?,?,?,?,?)")
                    .toString();
            ps = conn.prepareStatement(sql);
            ps.setString(1, name);
            ps.setDouble(2, Double.parseDouble(salary));
            ps.setString(3, gender);
            ps.setString(4, edu);
            ps.setString(5, StringUtil.arrayToString(hobbies));

            // 4.执行sql
            ps.executeUpdate();

            // 成功之后的响应
//            out.println("<h1 style='color:green;'>恭喜您,添加成功</h1>");
            // 添加成功之后跳转到员工列表对应的Servlet
            // 只有进入Servlet才会进行数据查询
            // 1.转发
            // 转发属于服务器内部控制权的转移,只能是同一个服务器中的资源
            // 因此,其地址的值只需要写当前项目中的资源即可,不需要应用名
//            request.getRequestDispatcher("/findAll").forward(request,response);
//            request.getRequestDispatcher("https://www.baidu.com/").forward(request,response);
//            request.getRequestDispatcher("/WEB-INF/test.jsp").forward(request,response);
            // 2.重定向
            // 重定向可以访问非当前服务器的资源,因此在使用重定向时需要指定应用名或者完整url地址
            // 重定向不共享请求与响应
            response.sendRedirect(request.getContextPath() + "/findAll");
//            response.sendRedirect("https://www.baidu.com/");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            request.setAttribute("empMsg","对不起,添加失败,错误原因:未找到驱动");
//            out.println("<h1 style='color:red;'>对不起,添加失败,错误原因:未找到驱动</h1>");
            request.getRequestDispatcher("/ems/addEmp.jsp").forward(request,response);
        } catch (SQLException e) {
            e.printStackTrace();
            request.setAttribute("empMsg","对不起,添加失败,错误原因:数据访问异常");
            request.getRequestDispatcher("/ems/addEmp.jsp").forward(request,response);
//            out.println("<h1 style='color:red;'>对不起,添加失败,错误原因:数据访问异常</h1>");
        } catch (Exception e) {
            e.printStackTrace();
            request.setAttribute("empMsg","服务器内部异常");
            request.getRequestDispatcher("/ems/addEmp.jsp").forward(request,response);
//            out.println("<h1 style='color:red;'>对不起,添加失败,错误原因:</h1>" + e.getMessage());
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    out.println("<h1 style='color:red;'>释放连接资源出错</h1>");
                }
            }
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    out.println("<h1 style='color:red;'>释放状态集资源出错</h1>");
                }
            }
        }
//        request.getRequestDispatcher("/WEB-INF/test.jsp").forward(request,response);
//        response.sendRedirect(request.getContextPath()+"/WEB-INF/test.jsp");
    }
}
